CREATE TABLE jms_dwd.dwd_departure_transfer_timely_route
(
    dt                        date COMMENT '日期',
    billcode                  varchar(80) comment '运单号',
    start_code                varchar(80) comment '始发地 发件中心',
    order_source_code         varchar(80) comment '订单来源:1.桃花岛，2.抖音-紫金山，3.快手-逍遥峰，4.其他',
    start_name                varchar(300) comment '始发地 发件中心',
    order_source_name         varchar(300) comment '订单来源',
    start_agent_code          varchar(80) comment '发件代理区',
    start_agent_name          varchar(300) comment '发件代理区',
    center_type               int comment '中心类型,1始发2中转',
    nextstationcode           varchar(80) comment '中心发件下一站',
    nextstation               varchar(300) comment '中心发件下一站',
    send_scantime             datetime comment '发件扫描时间',
    send_shipment_no          varchar(80) comment '发车任务号',
    planned_departure_time    datetime comment '规划发车时间',
    actual_departure_time     datetime comment '实际发车时间',
    next_planned_arrival_time datetime comment '下一站规划到达时间',
    packagecode               varchar(80) comment '所属包号',
    goods_type_code           varchar(80) comment '物品类型',
    goods_type_name           varchar(300) comment '物品类型',
    arrival_shipment_no       varchar(80) comment '到件任务号',
    arrival_time              datetime comment '到件时间',
    all_line_arrival_time     datetime comment '全链路到件时间',
    last_network_code         varchar(80) comment '到件任务对应上一站机构',
    last_network_name         varchar(300) comment '到件任务对应上一站机构',
    transfer_hours            double comment '中转时长',
    route_send_time           datetime comment '应发件时间',
    all_line_route_send_time  datetime comment '全链路应发件时间',
    is_timely                 int comment '是否及时 1及时,2路由缺失,3不及时',
    untimely_cause            int comment '不及时原因:1.路由缺失，2.错发，3.任务单问题，4.发车晚点，5.操作延误，6.经停线问题，7.无到达时间,8.及时，9.其他',
    all_line_is_timely        int comment '全链路是否及时，1及时2路由缺失3不及时',
    all_line_untimely_cause   int comment '全链路不及时原因:1.路由缺失，2.错发，3.任务单问题，4.发车晚点，5.操作延误，6.经停线问题，7.无到达时间,8.及时，9.其他'
) ENGINE=OLAP
    DUPLICATE KEY(`dt`, `billcode`,`start_code`,`order_source_code`)
    COMMENT '出港转运及时率明细'
    PARTITION BY RANGE(`dt`)
    (
    PARTITION  p20210912 VALUES [("2021-09-12"), ("2021-09-13")),
    PARTITION  p20210913
VALUES
[("2021-09-13"), ("2021-09-14")),
    PARTITION  p20210914 VALUES
[("2021-09-14"), ("2021-09-15")),
    PARTITION  p20210915 VALUES
[("2021-09-15"), ("2021-09-16")),
    PARTITION  p20210916 VALUES
[("2021-09-16"), ("2021-09-17")),
    PARTITION  p20210917 VALUES
[("2021-09-17"), ("2021-09-18")),
    PARTITION  p20210918 VALUES
[("2021-09-18"), ("2021-09-19")),
    PARTITION  p20210919 VALUES
[("2021-09-19"), ("2021-09-20")),
    PARTITION  p20210920 VALUES
[("2021-09-20"), ("2021-09-21")),
    PARTITION  p20210921 VALUES
[("2021-09-21"), ("2021-09-22")),
    PARTITION  p20210922 VALUES
[("2021-09-22"), ("2021-09-23")),
    PARTITION  p20210923 VALUES
[("2021-09-23"), ("2021-09-24")),
    PARTITION  p20210924 VALUES
[("2021-09-24"), ("2021-09-25")),
    PARTITION  p20210925 VALUES
[("2021-09-25"), ("2021-09-26")),
    PARTITION  p20210926 VALUES
[("2021-09-26"), ("2021-09-27")),
    PARTITION  p20210927 VALUES
[("2021-09-27"), ("2021-09-28")),
    PARTITION  p20210928 VALUES
[("2021-09-28"), ("2021-09-29")),
    PARTITION  p20210929 VALUES
[("2021-09-29"), ("2021-09-30")),
    PARTITION  p20210930 VALUES
[("2021-09-30"), ("2021-10-01")),
    PARTITION  p20211001 VALUES
[("2021-10-01"), ("2021-10-02")),
    PARTITION  p20211002 VALUES
[("2021-10-02"), ("2021-10-03")),
    PARTITION  p20211003 VALUES
[("2021-10-03"), ("2021-10-04")),
    PARTITION  p20211004 VALUES
[("2021-10-04"), ("2021-10-05")),
    PARTITION  p20211005 VALUES
[("2021-10-05"), ("2021-10-06")),
    PARTITION  p20211006 VALUES
[("2021-10-06"), ("2021-10-07")),
    PARTITION  p20211007 VALUES
[("2021-10-07"), ("2021-10-08")),
    PARTITION  p20211008 VALUES
[("2021-10-08"), ("2021-10-09")),
    PARTITION  p20211009 VALUES
[("2021-10-09"), ("2021-10-10")),
    PARTITION  p20211010 VALUES
[("2021-10-10"), ("2021-10-11")),
    PARTITION  p20211011 VALUES
[("2021-10-11"), ("2021-10-12")),
    PARTITION  p20211012 VALUES
[("2021-10-12"), ("2021-10-13")),
    PARTITION  p20211013 VALUES
[("2021-10-13"), ("2021-10-14")),
    PARTITION  p20211014 VALUES
[("2021-10-14"), ("2021-10-15")),
    PARTITION  p20211015 VALUES
[("2021-10-15"), ("2021-10-16")),
    PARTITION  p20211016 VALUES
[("2021-10-16"), ("2021-10-17")),
    PARTITION  p20211017 VALUES
[("2021-10-17"), ("2021-10-18")),
    PARTITION  p20211018 VALUES
[("2021-10-18"), ("2021-10-19")),
    PARTITION  p20211019 VALUES
[("2021-10-19"), ("2021-10-20")),
    PARTITION  p20211020 VALUES
[("2021-10-20"), ("2021-10-21")),
    PARTITION  p20211021 VALUES
[("2021-10-21"), ("2021-10-22"))
    )
    DISTRIBUTED BY HASH(`billcode`) BUCKETS 10
    PROPERTIES (
    "replication_num" = "3",
    "dynamic_partition.enable" = "true",
    "dynamic_partition.time_unit" = "DAY",
    "dynamic_partition.start" = "-100",
    "dynamic_partition.end" = "3",
    "dynamic_partition.prefix" = "p",
    "dynamic_partition.buckets" = "10",
    "in_memory" = "false",
    "storage_format" = "V2"
    );

ALTER TABLE jms_dwd.dwd_departure_transfer_timely_route
    ADD COLUMN mage_region_code varchar (80) KEY comment '管理大区编码' AFTER order_source_code;

ALTER TABLE jms_dwd.dwd_departure_transfer_timely_route
    ADD COLUMN mage_region_name varchar (80) comment '管理大区名称' AFTER mage_region_code;


ALTER TABLE jms_dwd.dwd_departure_transfer_timely_route
    ADD COLUMN sign_agent_code varchar (80) comment '签收代理区code';
ALTER TABLE jms_dwd.dwd_departure_transfer_timely_route
    ADD COLUMN sign_agent_name varchar (300) comment '签收代理区名称';
ALTER TABLE jms_dwd.dwd_departure_transfer_timely_route
    ADD COLUMN end_center_code varchar (80) comment '目的中心code';
ALTER TABLE jms_dwd.dwd_departure_transfer_timely_route
    ADD COLUMN end_center_name varchar (300) comment '目的中心名称';
ALTER TABLE jms_dwd.dwd_departure_transfer_timely_route
    ADD COLUMN center_arrvial_time datetime comment '转运中心到件扫描时间';
ALTER TABLE jms_dwd.dwd_departure_transfer_timely_route
    ADD COLUMN terminal_dispatch_code varchar (300) comment '三段码';



CREATE TABLE jms_dwd.dwd_departure_transfer_timely_route_new
(
    dt                        date COMMENT '日期',
    is_timely                 int comment '是否及时 1及时,2路由缺失,3不及时',
    untimely_cause            int comment '不及时原因:1.路由缺失，2.错发，3.任务单问题，4.发车晚点，5.操作延误，6.经停线问题，7.无到达时间,8.及时，9.其他',
    order_source_code         varchar(80) comment '订单来源:1.桃花岛，2.抖音-紫金山，3.快手-逍遥峰，4.其他',
    billcode                  varchar(80) comment '运单号',
    start_code                varchar(80) comment '始发地 发件中心',
    start_name                varchar(300) comment '始发地 发件中心',
    order_source_name         varchar(300) comment '订单来源',
    start_agent_code          varchar(80) comment '发件代理区',
    start_agent_name          varchar(300) comment '发件代理区',
    center_type               int comment '中心类型,1始发2中转',
    nextstationcode           varchar(80) comment '中心发件下一站',
    nextstation               varchar(300) comment '中心发件下一站',
    send_scantime             datetime comment '发件扫描时间',
    send_shipment_no          varchar(80) comment '发车任务号',
    planned_departure_time    datetime comment '规划发车时间',
    actual_departure_time     datetime comment '实际发车时间',
    next_planned_arrival_time datetime comment '下一站规划到达时间',
    packagecode               varchar(80) comment '所属包号',
    goods_type_code           varchar(80) comment '物品类型',
    goods_type_name           varchar(300) comment '物品类型',
    arrival_shipment_no       varchar(80) comment '到件任务号',
    arrival_time              datetime comment '到件时间',
    all_line_arrival_time     datetime comment '全链路到件时间',
    last_network_code         varchar(80) comment '到件任务对应上一站机构',
    last_network_name         varchar(300) comment '到件任务对应上一站机构',
    transfer_hours            double comment '中转时长',
    route_send_time           datetime comment '应发件时间',
    all_line_route_send_time  datetime comment '全链路应发件时间',
    all_line_is_timely        int comment '全链路是否及时，1及时2路由缺失3不及时',
    all_line_untimely_cause   int comment '全链路不及时原因:1.路由缺失，2.错发，3.任务单问题，4.发车晚点，5.操作延误，6.经停线问题，7.无到达时间,8.及时，9.其他',
    mage_region_code varchar (80)  comment '管理大区编码' ,
    mage_region_name varchar (80) comment '管理大区名称' ,
    sign_agent_code varchar (80) comment '签收代理区code',
    sign_agent_name varchar (300) comment '签收代理区名称',
    end_center_code varchar (80) comment '目的中心code',
    end_center_name varchar (300) comment '目的中心名称',
    center_arrvial_time datetime comment '转运中心到件扫描时间',
    terminal_dispatch_code varchar (300) comment '三段码'
) ENGINE=OLAP
    DUPLICATE KEY(`dt`,`is_timely`,`untimely_cause`,`order_source_code`, `billcode`,`start_code`)
    COMMENT '出港转运及时率明细'
    PARTITION BY RANGE(`dt`)
    (
START ("2022-05-01") END ("2022-06-10") EVERY (INTERVAL 1 day)
    )
    DISTRIBUTED BY HASH(`start_code`) BUCKETS 100
    PROPERTIES (
    "replication_num" = "3",
    "bloom_filter_columns" = "billcode",
    "dynamic_partition.enable" = "true",
    "dynamic_partition.time_unit" = "DAY",
    "dynamic_partition.start" = "-100",
    "dynamic_partition.end" = "3",
    "dynamic_partition.prefix" = "p",
    "dynamic_partition.buckets" = "10",
    "in_memory" = "false",
    "storage_format" = "V2"
    );

